package com.ibeeking.found.cop.b.rest.service.mq;

import com.ibeeking.nematos.rocketmq.annotation.MQProducer;
import com.ibeeking.nematos.rocketmq.base.AbstractMQProducer;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.common.message.Message;

@MQProducer
public class CopMqProducer extends AbstractMQProducer {

    /**
     * 	可重写方法，处理发送后的逻辑
     * @param message
     * @param sendResult
     */
    public void doAfterSyncSend(Message message, SendResult sendResult) {
    }

}
